package main

import (
	"context"
	"git.900sui.cn/kc/base/utils"
	"git.900sui.cn/kc/kcgin"
	"git.900sui.cn/kc/kcgin/logs"
	"git.900sui.cn/kc/rpcinterface/client/pay"
	"github.com/robfig/cron"
	"time"
)

//代付资金信息进入对应的渠道任务

//执行任务
func execTask(){
	new(utils.KcLog).GetInstance( kcgin.AppConfig.String("crontab.log.agentDataToChannel") )
	rpcPay := new(pay.Pay).Init()
	args := int( time.Now().Local().Unix() )
	reply := false
	err := rpcPay.AngelChannel(context.Background(), &args, &reply )
	if err != nil{
		utils.Logerr.Printf("代付资金信息进入对应的渠道任务执行失败, 错误信息：%s \n", err.Error())
		return
	}
	utils.Logerr.Printf("代付资金信息进入对应的渠道任务执行完成 \n")
}

func main() {
	logs.Info("Environment Variable:MSF_ENV:", kcgin.KcConfig.RunMode)
	c := cron.New()
	//spec := "00 00 01 * * ?" //秒-分-时-日-月-周【忽略】
	spec := "00 30 11 * * ?" //秒-分-时-日-月-周【忽略】
	_ = c.AddFunc(spec,execTask)
	c.Start()
	select {}
}

